package com.hksj.mqtt.callback;

import com.hksj.mqtt.client.IMqttClient;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

public interface MqttCallBackAdapter {
    void initSubscript(IMqttClient iMqttClient);

    void handleMsg(String topic, MqttMessage mqttMessage);

    ThreadPoolTaskExecutor getExecutor();
}
